package com.qingcloud.df.executor.queue.publisher;

/**
 * 组件发布者
 * @author yangfan
 * @date 2022-01-20
 * @author yangfan
 * @date 2022/1/17 14:47
 */
public interface ComponentPublisher {

    /**
     * 发送消息
     * @param topic 数据发送到的topic
     * @param data  要发送的数据
     */
    void send(String topic, String messageFrom, String data);


}
